package cn.itcast.flink.streaming.task;

/**
 * flink流式计算task任务基类，封装两个方法
 * 1、创建流式执行环境，设置属性：检查点、状态后端、重启策略
 * 2、获取kafka中的数据，消费topic中的数据
 * @author lilulu
 * @date 2023-04-16 21:31
 */
public abstract class BaseTask {

}
